package com.tcoiss.message.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.tcoiss.message.domain.MqCommonRegistryMessage;
import org.apache.ibatis.annotations.Param;

import java.util.List;

public interface MqCommonRegistryMessageMapper extends BaseMapper<MqCommonRegistryMessage> {

    public int add(@Param("commonRegistryMessage") MqCommonRegistryMessage commonRegistryMessage);

    public List<MqCommonRegistryMessage> findMessage(@Param("excludeIds") List<Integer> excludeIds);

    public int cleanMessage(@Param("messageTimeout") int messageTimeout);
}
